package sufutian.com.englishvoicetrans.storage;//[START all]
/*
 * Copyright (c) 2014 Google Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
 * in compliance with the License. You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software distributed under the License
 * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
 * or implied. See the License for the specific language governing permissions and limitations under
 * the License.
 */

import android.os.Environment;

import com.google.api.client.http.InputStreamContent;
import com.google.api.services.storage.Storage;
import com.google.api.services.storage.model.Bucket;
import com.google.api.services.storage.model.ObjectAccessControl;
import com.google.api.services.storage.model.Objects;
import com.google.api.services.storage.model.StorageObject;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.security.GeneralSecurityException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

/**
 * Main class for the Cloud Storage JSON API sample.
 * <p>
 * Demonstrates how to make an authenticated API call using the Google Cloud Storage API client
 * library for java, with Application Default Credentials.
 */
public class StorageSample {

    /**
     * Global instance of the JSON factory.
     */
    private static final String TEST_FILENAME = "json-test.txt";

    // [START list_bucket]

    /**
     * Fetch a list of the objects within the given bucket.
     *
     * @param bucketName the name of the bucket to list.
     * @return a list of the contents of the specified bucket.
     */
    public static List<StorageObject> listBucket(String bucketName)
            throws IOException, GeneralSecurityException {
        Storage client = StorageFactory.getService();
        Storage.Objects.List listRequest = client.objects().list(bucketName);

        List<StorageObject> results = new ArrayList<StorageObject>();
        Objects objects;

        // Iterate through each page of results, and add them to our results list.
        do {
            objects = listRequest.execute();
            // Add the items in this page of results to the list we'll return.
            results.addAll(objects.getItems());

            // Get the next page, in the next iteration of this loop.
            listRequest.setPageToken(objects.getNextPageToken());
        } while (null != objects.getNextPageToken());

        return results;
    }
    // [END list_bucket]

    // [START get_bucket]

    /**
     * Fetches the metadata for the given bucket.
     *
     * @param bucketName the name of the bucket to get metadata about.
     * @return a Bucket containing the bucket's metadata.
     */
    public static Bucket getBucket(String bucketName) throws IOException, GeneralSecurityException {
        Storage client = StorageFactory.getService();

        Storage.Buckets.Get bucketRequest = client.buckets().get(bucketName);
        // Fetch the full set of the bucket's properties (e.g. include the ACLs in the response)
        bucketRequest.setProjection("full");
        return bucketRequest.execute();
    }
    // [END get_bucket]

    // [START upload_stream]

    /**
     * Uploads data to an object in a bucket.
     *
     * @param name        the name of the destination object.
     * @param contentType the MIME type of the data.
     * @param file        the file to upload.
     * @param bucketName  the name of the bucket to create the object in.
     */
    public static void uploadFile(
            String name, String contentType, File file, String bucketName)
            throws IOException, GeneralSecurityException {
        InputStreamContent contentStream = new InputStreamContent(
                contentType, new FileInputStream(file));
        // Setting the length improves upload performance
        contentStream.setLength(file.length());
        StorageObject objectMetadata = new StorageObject()
                // Set the destination object name
                .setName(name)
                // Set the access control list to publicly read-only
                .setAcl(Arrays.asList(
                        new ObjectAccessControl().setEntity("allUsers").setRole("READER")));

        // Do the insert
        Storage client = StorageFactory.getService();
        Storage.Objects.Insert insertRequest = client.objects().insert(
                bucketName, objectMetadata, contentStream);

        insertRequest.execute();
    }
    // [END upload_stream]

    // [START delete_object]

    /**
     * Deletes an object in a bucket.
     *
     * @param path       the path to the object to delete.
     * @param bucketName the bucket the object is contained in.
     */
    public static void deleteObject(String path, String bucketName)
            throws IOException, GeneralSecurityException {
        Storage client = StorageFactory.getService();
        client.objects().delete(bucketName, path).execute();
    }
    // [END delete_object]

    /**
     * Exercises the class's functions - gets and lists a bucket, uploads and deletes an object.
     *
     * @param args the command-line arguments. The first argument should be the bucket name.
     */
    public static void main(String[] args) {
        if (args.length < 1) {
            System.out.println("Usage: StorageSample <bucket-name>");
            System.exit(1);
        }

        String bucketName = args[0];

        try {
            // Get metadata about the specified bucket.
            Bucket bucket = getBucket(bucketName);
            System.out.println("name: " + bucketName);
            System.out.println("location: " + bucket.getLocation());
            System.out.println("timeCreated: " + bucket.getTimeCreated());
            System.out.println("owner: " + bucket.getOwner());


            // List the contents of the bucket.
            List<StorageObject> bucketContents = listBucket(bucketName);
            if (null == bucketContents) {
                System.out.println(
                        "There were no objects in the given bucket; try adding some and re-running.");
            }
            for (StorageObject object : bucketContents) {
                System.out.println(object.getName() + " (" + object.getSize() + " bytes)");
            }


            // Create a temp file to upload


            File tempFile = new File(Environment.getExternalStorageDirectory().getAbsolutePath() + "/sufutian" + "/sufutian.wav");


            // Upload it
            uploadFile(TEST_FILENAME, "text/plain", tempFile, bucketName);

            // Now delete the file
            deleteObject(TEST_FILENAME, bucketName);

        } catch (IOException e) {
            System.err.println(e.getMessage());
            System.exit(1);
        } catch (Throwable t) {
            t.printStackTrace();
            System.exit(1);
        }
    }
}
//[END all]
